package sanshui.system.trade.factory.data;

import java.time.LocalDateTime;
import java.util.Map;

public class DataProcessor {
//    public void alignTimestamps(Map<String, TickData> tickDataMap,
//                                Map<String, KLineData> klineDataMap) {
//        klineDataMap.forEach((symbolFreq, kline) -> {
//            String symbol = symbolFreq.split("_")[0];
//            TickData ticks = tickDataMap.get(symbol);
//
//            ticks.getTimestamps().forEach(tickTs -> {
//                // 找到该tick对应的K线时间戳
//                LocalDateTime klineTs = alignToKlineFrequency(tickTs, kline.getFrequency());
//                kline.getBars().computeIfAbsent(klineTs, ts -> new Bar(ts))
//                     .update(tickTs, ticks.getPrice(tickTs), ticks.getVolume(tickTs));
//            });
//        });
//    }
}